package qiyu.live.im.router.provider.rpc;

import jakarta.annotation.Resource;
import org.apache.dubbo.config.annotation.DubboService;
import org.qiyu.live.im.dto.ImMsgBody;
import qiyu.live.im.router.interfaces.IMRouterRpc;
import qiyu.live.im.router.provider.service.IMRouterService;

import java.util.List;

/**
 * Created with IntelliJ IDEA.
 * Description:
 * User: sfx
 * Date: 2023-10-12
 * Time: 20:02
 */
@DubboService
public class IMRouterRpcImpl implements IMRouterRpc {

    @Resource
    private IMRouterService imRouterService;

    @Override
    public boolean sendMsg(ImMsgBody imMsgBody) {
        return imRouterService.sendMsg(imMsgBody);
    }


    @Override
    public boolean batchSendMsg(List<ImMsgBody> imMsgBodies) {
        return imRouterService.batchSendMsg(imMsgBodies);
    }
}